from celery import Celery

broker = 'redis://127.0.0.1:6379/11'
backend = 'redis://127.0.0.1:6379/12'
include = ['celery_task.tasks',]
app = Celery(broker=broker, backend=backend, include=include)

# 启动celery服务的命令：
# 前提：一定要进入celery_task所属的文件夹
# celery worker -A celery_task -l info -P eventlet
